package top.igotcha.hdfs;

import org.apache.hadoop.conf.Configuration;
import org.apache.hadoop.fs.FileSystem;
import org.apache.hadoop.fs.Path;
import org.junit.jupiter.api.Test;

import java.net.URI;

/**
 * @time 2021/1/10
 * @auth Gotcha
 * @describe
 */
public class HdfsMkdir {
    //创建文件、文件夹(支持创建多级目录)
    @Test
    public void mkdirs() throws  Exception{
        FileSystem fileSystem = FileSystem.get(new URI("hdfs://192.168.127.110:8020"), new Configuration());
        boolean isMkdirs01 = fileSystem.mkdirs(new Path("/test03"));
        System.out.println("文件夹创建是否成功："+isMkdirs01);
        boolean isMkdirs02 = fileSystem.mkdirs(new Path("/test01/a.txt"));
        System.out.println("文件创建是否成功："+isMkdirs02);
        fileSystem.close();
    }
}
